package com.feihong.activity.service;

import com.fasterxml.jackson.core.JsonProcessingException;
import com.feihong.activity.entity.EquipmentRequest;
import com.feihong.activity.entity.Sensor;

import java.util.List;

/**
 * @author Filter
 */
public interface ThirdPartyService {

    /**
     *
     * @param sensorList
     * @return result(设备共计xxx条，成功同步xxx条，失败xxx条)
     * @throws JsonProcessingException
     */
    String equipmentDataReporting (List<Sensor> sensorList) throws JsonProcessingException;

    /**
     * 推送数据到kafka
     * @param sensors
     */
    <T> Integer  pushKafkaByList(List<T> sensors);
}
